﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Lails.MQClient
{
    public class AliyunMQClinet : MQClient
    {
        public AliyunMQClinet(string address, string username, string password, string clientID, string appid = "/")
            : base(address, username, password, clientID)
        {

        }

        public override bool Publish(string topic, byte[] body, MessageArgs arg = null)
        {
            throw new NotImplementedException();
        }

        public override bool Subscribe(string topic, Func<byte[], bool> subscribe, MessageArgs arg = null)
        {
            throw new NotImplementedException();
        }

        public override bool Subscribe(string topic, Func<MessageData, bool> subscribe, MessageArgs arg = null)
        {
            throw new NotImplementedException();
        }

        public override bool UnSubscribe(string topic)
        {
            throw new NotImplementedException();
        }

        protected override string FormatTopic(string topic)
        {
            throw new NotImplementedException();
        }

        protected override bool _Connect()
        {
            throw new NotImplementedException();
        }

        protected override bool _DisConnect()
        {
            throw new NotImplementedException();
        }
    }
}
